package com.gzl.autotest.utils;

import com.alibaba.fastjson.JSONObject;
import com.gzl.autotest.entity.Sql;
import org.apache.log4j.Logger;
import java.util.List;
public class InitSqlUtil {
    public static Logger logger = Logger.getLogger(InitSqlUtil.class);

    public static void doInitSql(String initSql) {
        // 初始化sql解析为对象
        List<Sql> sqls = JSONObject.parseArray(initSql, Sql.class);
        // 遍历获取sql，并执行
        for (Sql sql_ : sqls) {
            String sqlNo = sql_.getSqlNo();
            String sql = sql_.getSql().trim();
            // logger.info("获取到的sql：sqlNo="+sqlNo+", sql=" + sql);
            String prefix = sql.split(" ")[0].trim().toLowerCase();
            if (prefix.startsWith("select")){
                logger.info("=====执行select语句：" + sql_);
                // 执行查询sql，获取执行结果
                JDBCUtil.query(sql);
            } else if (prefix.startsWith("delete")){
                logger.info("=====执行delete语句：" + sql_);
                JDBCUtil.nonQuery(sql);
            } else if (prefix.startsWith("update")){
                logger.info("=====执行update语句：" + sql_);
                JDBCUtil.nonQuery(sql);
            } else if (prefix.startsWith("insert")){
                logger.info("=====执行insert语句：" + sql_);
                JDBCUtil.nonQuery(sql);
            } else {
                logger.info("=====sql语句【"+ sql_ +"】不符合规范");
            }
        }
    }
}